package com.chenjt.netty.one_helloWorld.helloWorld;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

/**
 * 流程：需要启动一个ServerBootstrap服务器，将bossGroup和workerGroup两个线程组添加进去，还可以添加处理器
 *
 * @author chenjt
 * @date 2024/8/8 9:36
 */
public class TestServer {

    public static void main(String[] args) throws InterruptedException {
        /**
         * 定义两个线程组
         * （其实就是两个死循环，
         *  不断的接收客户端发起的连接，
         *  连接进来之后对连接进行处理，紧接着循环继续运行）
         *
         *  bossGroup：这个线程组不断的接收连接，不对连接进行处理，
         *             紧接着把连接转给workerGroup线程组，由于workerGroup对连接
         *             进行业务处理
         *
         */
        NioEventLoopGroup bossGroup = new NioEventLoopGroup();//事件循环组
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            //用于启动服务端的类,childHandler是将处理类丢给workerGroup，如果是handler()就是将处理类丢给bossGroup
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup,workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new TestServerInitializer());//自己的处理器，请求来了之后可以由自己的处理器进行处理

            // 绑定监听的端口
            ChannelFuture channelFuture = serverBootstrap.bind(8899).sync();
            // 绑定关闭的监听
            channelFuture.channel().closeFuture().sync();
        } finally {
            //优雅的关闭
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }

    }

}
